package org.niit.controller

import org.apache.spark.streaming.dstream.DStream
import org.niit.bean.Answer
import org.niit.service.{EDUDataService, EDURecomendService}

/**
 * Date:2025/6/11
 * Author：Ys
 * Description:
 */
class EDUDataController {
  val eduDataService = new EDUDataService()
  val eduRecomendService = new EDURecomendService()

  def dispatch(data:DStream[Answer]): Unit = {
    eduDataService.dataAnalysis(data)
    eduRecomendService.dataAnalysis(data)
  }

}
